package test01;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;


/**
 * @author 帅小伙
 * @date 2022/1/2
 * @description
 */
public class Producer {

    private static final String QUEUE_NAME = "hello";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("47.96.19.90");
        factory.setUsername("mubei");
        factory.setPassword("020323");
        Connection connection = factory.newConnection();
        // 得到连接的channel
        Channel channel = connection.createChannel();


        /*
        * 声明一个队列
        * 1.队列名称
        * 2.队列是否持久化
        *   true 持久
        * 3.是否只让一个消费者独自消费
        *   true 独自
        * 4.消费者断开连接是否删除队列
        *       true   代表删除
        * 5.其他参数
        * */
        channel.queueDeclare(QUEUE_NAME,false,false,false,null);



        /**
         * 1. 交换机的名称   ""默认的交换机
         * 2.  路由的key
         *          默认采用队列名称作为路由key  该消息会路由到该队列中
         * 3. 其他配置参数
         * 4. 发生内容
         */
        String msg = "hello world";
        channel.basicPublish("",QUEUE_NAME,null,msg.getBytes());
        System.out.println("消息发送完成");

        channel.close();
        connection.close();
    }


}
